# from celery import Celery
from celery import shared_task
import time


# app = Celery('App')
# @ app.task
# def test():
#     pass
#
# # app/tasks.py, 可以复用的task


@shared_task
def add(x, y):
    time.sleep(2)
    print("测试celery")
    return x + y
